<?php
/**
 * 生产者->队列 ->消费者1
 *            ->消费者2
 */
require __DIR__ . '/../../vendor/autoload.php';
require __DIR__ . '/../Mqtt.php';

$mqtt = new Mqtt;
$mqtt->createChannel();

/*
创建一个队列：
    @param queueName 队列名称，
    @param passive 设置为true表示：如果存在这个队列则返回队列的信息 ，如果不存在这个队列则抛异常
    @param durable 是否持久化（重启后队列还存在） 
    @param exclusive 是否独占队列，该队列仅对首次声明它的连接可见，并在连接断开时自动删除
    @param auto_delete 所有消费断开连接后是否自动删除队列
    @param nowait = false 不等待处理结果
*/
$mqtt->createQueue('mqtt_worker', false, true, false, false);

$i = 1;
while(true) {
    $msg = "hello,mqtt_{$i}\n";
    $mqtt->publishMsg($msg, [
        // 2-消息持久化
        'delivery_mode' => 2
    ]);
    echo $msg;
    $i++;

    // sleep(1);
}

$mqtt->close();
